package com.tsx.kafka.cunsumer;

import org.apache.kafka.clients.consumer.ConsumerRecord;



/**
 * 
 * @author tangsixiang
 *
 */
public class KafkaCunsumerReceiver extends AbstractReceiver {

	@Override
	public String topic() {
		return "jiuzhi";
	}

	@Override
	public void toDealWith(ConsumerRecord<String, String> record) {
    	System.out.printf("offset = %d, key = %s, value = %s  " , record.offset(), record.key(), record.value());
    	System.out.println("ConsumerRecord--"+record.topic()+" "+record.offset()+" partition :"+record.partition());
	}

}
